package org.tao.lightningmq.broker.rebalance.strategy;

import org.tao.lightningmq.broker.rebalance.ConsumerInstance;

import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Set;

/**
 * @Author lht
 * @date 2025/1/20 - 12:44
 * @description:
 */
public class ReBalanceInfo {
    private Map<String, List<ConsumerInstance>> consumeInstanceMap;
    //消费者发生变化的消费组
    private Map<String, Set<String>> changeConsumerGroupMap = new HashMap<>();

    public Map<String, List<ConsumerInstance>> getConsumeInstanceMap() {
        return consumeInstanceMap;
    }

    public void setConsumeInstanceMap(Map<String, List<ConsumerInstance>> consumeInstanceMap) {
        this.consumeInstanceMap = consumeInstanceMap;
    }

    public Map<String, Set<String>> getChangeConsumerGroupMap() {
        return changeConsumerGroupMap;
    }
}
